package aps

import glory.xxd.ConsumerUtil

/**
 * 监听
 */
class TopicMsgThreadService extends Thread{

    public static Map newMsgMap = new HashMap<String,LinkedList>()
    public static Map alertMap = new HashMap<String,LinkedList>()
    def msgName
    public static int max = 30

     public  void  run(){
        println "topic主动监听程序已启动!(${msgName})"
        ConsumerUtil.getTopicMsg(msgName,max,newMsgMap)
    }
}
